package com.example.demo.procss;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

/**
 * @Description
 * @Author liumin0901@sunwayworld.com
 * @Date 2021/4/27 18:57
 */
public interface MqProcess {

    @Input("input1")
    SubscribableChannel mq_input1();

    @Output("output1")
    MessageChannel mq_output1();
}
